package com.junjie.blibli.service;

import com.junjie.blibli.Entity.UserMoment;
import org.apache.rocketmq.client.exception.MQBrokerException;
import org.apache.rocketmq.client.exception.MQClientException;
import org.apache.rocketmq.remoting.exception.RemotingException;

import java.util.List;

public interface UserMomentService {
    void addUserMoments(UserMoment userMoment) throws Exception;

    List<UserMoment> getUserSubscribedMoments(Long userId);
}
